package main.scala.thread

class MyTask extends Runnable {

  /**
   * 线程run方法
   */
  override def run(): Unit = {
    // 进行计算任务
    ScalaThreadLab.task()

    // 修改访问次数，需要加锁操作
    MyArray.lock.lock()
    MyArray.count += 1
    MyArray.lock.unlock()

    // 当达到target时，打印总的时间
    if(MyArray.count == MyArray.target) {
      ScalaThreadLab.printTime()
    }
  }

}
